# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
#from jms.time_sensor.time_after_00_30 import time_after_00_30

spmi_ods__spmi_composite_bill = BashOperator(
    task_id='spmi_ods__spmi_composite_bill',
    execution_timeout=timedelta(hours=2),
    email=['yl_etl@yl-scm.com','lukunming@jtexpress-scm.com'],
    # name='spmi_ods__spmi_composite_bill_{{ execution_date | date_add(1) | cst_ds }}',
    bash_command="jms/ods/mysql/spmi/spmi_composite_bill/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)

